package com.flc.realtime.mq.consumer;

import org.apache.rocketmq.client.exception.MQClientException;

/**
 * @author haizi
 * @date 2018/1/31
 */
public interface Consumer {

    /**
     * 消费者初始化和开启接收业务
     */
    void start() throws MQClientException;
}
